package com.demo.webflux.simple2;

import java.util.List;

import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;

public interface ChatService<T> {

	Flux<T> getMessageStream(); // 在聊天中返回无限的新消息流

	Mono<List<T>> getMessageAfter(String messageId); // 使我们能够检索具有特定消息id的消息列表

}
